package com.xian.java.batch.function;

import org.apache.flink.api.java.ExecutionEnvironment;
import org.apache.flink.api.java.operators.DataSource;

/**
 * 测试map function  & rich function
 */
public class MapFunctionTest {
    public static void main(String[] args) throws Exception {
        ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
        DataSource<String> stringDataSource = env.readTextFile("d:/test/a.txt");





        stringDataSource.print();

    }
}
